package com.heima.article.processor;

import org.apache.kafka.streams.kstream.KStream;
import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;

/**
 * 实时流式计算处理器 1.指定数据从何而来  2.指定经过计算结果去往何处
 * @author: itheima
 * @create: 2022-07-13 15:12
 */
public interface IHotArticleProcessor {

    /**
     * 监听文章行为数据来源话题
     * @return
     */
    @Input("hot_article_score_topic")
    public KStream<String, String> input();


    /**
     * 经过实时流式计算后结果话题
     * @return
     */
    @Output("hot_article_result_topic")
    public KStream<String, String> output();
}
